package com.zlf.demo;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @ClassName Sink
 * @Description TODO
 * @Author zlf
 * @Date 2021/5/19 13:41
 */
public interface MyProcessor {

    String DEMO_INPUT = "demo_input";

    String DEMO_OUTPUT = "demo_output";

    String TEST_INPUT = "test_input";

    String TEST_OUTPUT = "test_output";

    @Input(MyProcessor.DEMO_INPUT)
    SubscribableChannel demoInput();

    @Output(MyProcessor.DEMO_OUTPUT)
    MessageChannel demoOutput();

    @Input(MyProcessor.TEST_INPUT)
    SubscribableChannel testInput();

    @Output(MyProcessor.TEST_OUTPUT)
    MessageChannel testOutput();

}
